package com.tjf.myjetpackdemo.RxObserverModel;

/**
 * @author: tjf
 * @date: 2023-06-07
 * @desc：具体被观察者
 */
public interface ObservableOnSubscribe<T> {
    //为每一个订阅的观察者提供一个能进行消息发送的功能
    void subscribe(Emitter<T> emitter);//给定observer的订阅功能

}
